/**
 * 接收mq消息
 */
package com.boat.sample.ddd.interfaces.mq;